home *** CD-ROM | disk | FTP | other *** search
/ InfoMagic Internet Tools 1995 April / Internet Tools.iso / applic / ntp / depredated / ntp.3.4 / patches / patch10.Z / patch10
Encoding:
Text File  |  1991-09-29  |  25.8 KB  |  908 lines
  1. System: ntp version 3.4
  2. Patch #: 10
  3. Priority: 
  4.  
  5. From:
  6.  
  7. Description:
  8. In the Makefile, remove references to the readclock.c module.
  9.  
  10. New clockhopper supression code.
  11.  
  12. Fix minor problem in ntp.c to get sin_family set in the proper place.
  13. Specify default file for drift value and more peer flag definitions to
  14. reflect various stages of clock selection critera.
  15.  
  16. Add code to count number of peer switches and inhibited peer switches.  Clock
  17. selection code has been updated to reflect 21 April 1989 draft of NTP spec.
  18.  
  19. Add code to save the value of the drift compensation register to a file every
  20. hour.  Add additional configuration file directives which can specify the same
  21. information as on the command line.
  22.  
  23. ntpdc now will display addional peer flags which indicate how far through
  24. the clock selection process a peer was considered.
  25.  
  26.  
  27. Repeat-By:
  28.  
  29. Fix:    From rn, say "| patch -p -N -d DIR", where DIR is your ntp source
  30.     directory.  Outside of rn, say "cd DIR; patch -p -N <thisarticle".
  31.     If you don't have the patch program, apply the following by hand,
  32.     or get patch (version 2.0, latest patchlevel).
  33.  
  34.     After patching:
  35.         make depend
  36.         make
  37.         make install
  38.  
  39.     If patch indicates that patchlevel is the wrong version, you may need
  40.     to apply one or more previous patches, or the patch may already
  41.     have been applied.  See the patchlevel.h file to find out what has or
  42.     has not been applied.  In any event, don't continue with the patch.
  43.  
  44.     If you are missing previous patches they can be obtained from me:
  45.  
  46.     Louis A. Mamakos
  47.     louie@trantor.umd.edu
  48.  
  49.     You can also get the patches via anonymous FTP from
  50.     trantor.umd.edu.
  51.  
  52. Index: patchlevel.h
  53. Prereq: 9
  54. 1c1
  55. < #define PATCHLEVEL 9
  56. ---
  57. > #define PATCHLEVEL 10
  58.  
  59. Index: Makefile
  60. *** Makefile.old    Wed May  3 15:17:41 1989
  61. --- Makefile    Wed May  3 15:17:44 1989
  62. ***************
  63. *** 1,6 ****
  64. ! # $Source: /usr/users/louie/ntp/RCS/Makefile,v $ $Revision: 3.4.1.5 $ $Date: 89/04/10 15:54:19 $
  65.   #
  66.   # $Log:    Makefile,v $
  67.   # Revision 3.4.1.5  89/04/10  15:54:19  louie
  68.   # Add dependency for ntpd.o on ntp.h so things sorta work even without doing a
  69.   # "make depend".  Trash "ci" rule.
  70. --- 1,9 ----
  71. ! # $Source: /usr/users/louie/ntp/RCS/Makefile,v $ $Revision: 3.4.1.6 $ $Date: 89/05/03 15:08:06 $
  72.   #
  73.   # $Log:    Makefile,v $
  74. + # Revision 3.4.1.6  89/05/03  15:08:06  louie
  75. + # In the Makefile, remove references to the readclock.c module.
  76. + # 
  77.   # Revision 3.4.1.5  89/04/10  15:54:19  louie
  78.   # Add dependency for ntpd.o on ntp.h so things sorta work even without doing a
  79.   # "make depend".  Trash "ci" rule.
  80. ***************
  81. *** 106,121 ****
  82.   # Source files
  83.   #
  84.   SRCS=    ntp.c ntpd.c ntpdc.c ntpsubs.c ntp_proto.c ntp_sock.c ntp_adjust.c
  85. ! NTPDSRC= ntpd.c ntpsubs.c ntp_proto.c ntp_sock.c ntp_adjust.c readclock.c
  86.   
  87.   # Object files
  88.   #
  89.   OBJS=    ntp.o ntpd.o ntpdc.o ntpsubs.o ntp_proto.o ntp_sock.o ntp_adjust.o
  90.   NTPDOBJ= ntpd.o ntpsubs.o ntp_proto.o ntp_sock.o ntp_adjust.o
  91. - #
  92. - # if using REFCLOCK
  93. - #
  94. - #NTPDOBJ= ntpd.o ntpsubs.o ntp_proto.o ntp_sock.o ntp_adjust.o readclock.o
  95.   
  96.   DIST= README Makefile man ${SRCS} ${HDRS} ntp.conf test.c extract.pl stat.pl
  97.   PROGS=    ntp ntpd ntpdc ntest
  98. --- 109,120 ----
  99.   # Source files
  100.   #
  101.   SRCS=    ntp.c ntpd.c ntpdc.c ntpsubs.c ntp_proto.c ntp_sock.c ntp_adjust.c
  102. ! NTPDSRC= ntpd.c ntpsubs.c ntp_proto.c ntp_sock.c ntp_adjust.c
  103.   
  104.   # Object files
  105.   #
  106.   OBJS=    ntp.o ntpd.o ntpdc.o ntpsubs.o ntp_proto.o ntp_sock.o ntp_adjust.o
  107.   NTPDOBJ= ntpd.o ntpsubs.o ntp_proto.o ntp_sock.o ntp_adjust.o
  108.   
  109.   DIST= README Makefile man ${SRCS} ${HDRS} ntp.conf test.c extract.pl stat.pl
  110.   PROGS=    ntp ntpd ntpdc ntest
  111.  
  112. Index: README
  113. *** README.old    Wed May  3 15:17:55 1989
  114. --- README    Wed May  3 15:17:58 1989
  115. ***************
  116. *** 1,4 ****
  117. ! README for UNIX NTP release $Date: 89/04/08 10:35:44 $ $Revision: 3.4.1.4 $
  118.   
  119.   
  120.   
  121. --- 1,4 ----
  122. ! README for UNIX NTP release $Date: 89/05/03 15:08:58 $ $Revision: 3.4.1.5 $
  123.   
  124.   
  125.   
  126. ***************
  127. *** 48,53 ****
  128. --- 48,68 ----
  129.       7) Fire up ntpd in /etc/rc.local
  130.   
  131.   History:
  132. + 5/3/89
  133. +     The changes to the ntp_proto.c module for clockhopper suppression have
  134. +     been tweaked once more, ever so slightly to conform with the 21 April
  135. +     1989 draft of the NTP spec.  We won't switch peers if the current 
  136. +     peer makes it into the final selection list, unless the first peer on
  137. +     the selection list is of a higher stratum than the current peer.
  138. + 
  139. +     The ntpd.c/hourly() function now saves the value of the drift
  140. +     compensation register to a file (/etc/ntp.drift by default).  In fact,
  141. +     the last 5 hourly samples are written to the file, as well as how
  142. +     many hours the ntpd process has been running.  Ntpd will also attempt
  143. +     to intialize the value of the drift compensation register from this
  144. +     file when it is started up.  The hourly stats: log message has been
  145. +     augmented to log additional information.
  146. + 
  147.   4/8/89
  148.       Changes to the ntp_proto.c module to supress peer switching when the
  149.       dispersion between the newly selected peer and the currently selected
  150.  
  151. Index: ntp.c
  152. *** ntp.c.old    Wed May  3 15:18:09 1989
  153. --- ntp.c    Wed May  3 15:18:11 1989
  154. ***************
  155. *** 1,9 ****
  156.   #ifndef    lint
  157. ! static char *rcsid = "$Source: /usr/users/louie/ntp/RCS/ntp.c,v $ $Revision: 3.4.1.4 $ $Date: 89/04/07 18:04:49 $";
  158.   #endif    lint
  159.   
  160.   /*
  161.    *  $Log:    ntp.c,v $
  162.    * Revision 3.4.1.4  89/04/07  18:04:49  louie
  163.    * Removed unused variables from ntp.c program.
  164.    * 
  165. --- 1,12 ----
  166.   #ifndef    lint
  167. ! static char *rcsid = "$Source: /usr/users/louie/ntp/RCS/ntp.c,v $ $Revision: 3.4.1.5 $ $Date: 89/05/03 15:09:53 $";
  168.   #endif    lint
  169.   
  170.   /*
  171.    *  $Log:    ntp.c,v $
  172. +  * Revision 3.4.1.5  89/05/03  15:09:53  louie
  173. +  * Fix minor problem in ntp.c to get sin_family set in the proper place.
  174. +  * 
  175.    * Revision 3.4.1.4  89/04/07  18:04:49  louie
  176.    * Removed unused variables from ntp.c program.
  177.    * 
  178. ***************
  179. *** 147,152 ****
  180. --- 150,156 ----
  181.       } else
  182.           dst.sin_port = sp->s_port;
  183.   
  184. +     dst.sin_family = AF_INET;
  185.       while ((n = getopt(argc, argv, "vsf")) != EOF) {
  186.           switch (n) {
  187.           case 'v':
  188. ***************
  189. *** 165,172 ****
  190.   
  191.           if (argv[host] == NULL)
  192.               continue;
  193. -         dst.sin_family = AF_INET;
  194. -         dst.sin_port = sp->s_port;
  195.   
  196.           hp = NULL;
  197.           HostAddr = inet_addr(argv[host]);
  198. --- 169,174 ----
  199.  
  200. Index: ntp.h
  201. *** ntp.h.old    Wed May  3 15:18:22 1989
  202. --- ntp.h    Wed May  3 15:18:26 1989
  203. ***************
  204. *** 1,7 ****
  205. ! /* $Source: /usr/users/louie/ntp/RCS/ntp.h,v $ $Revision: 3.4.1.5 $ $Date: 89/04/10 15:55:42 $ */
  206.   
  207.   /*
  208.    *  $Log:    ntp.h,v $
  209.    * Revision 3.4.1.5  89/04/10  15:55:42  louie
  210.    * Provide default value for number of bits/byte if not defined.  Compute the
  211.    * Window shift mask inside of conditional code on XTAL so we get the correct
  212. --- 1,11 ----
  213. ! /* $Source: /usr/users/louie/ntp/RCS/ntp.h,v $ $Revision: 3.4.1.6 $ $Date: 89/05/03 15:11:06 $ */
  214.   
  215.   /*
  216.    *  $Log:    ntp.h,v $
  217. +  * Revision 3.4.1.6  89/05/03  15:11:06  louie
  218. +  * Specify default file for drift value and more peer flag definitions to
  219. +  * reflect various stages of clock selection critera.
  220. +  * 
  221.    * Revision 3.4.1.5  89/04/10  15:55:42  louie
  222.    * Provide default value for number of bits/byte if not defined.  Compute the
  223.    * Window shift mask inside of conditional code on XTAL so we get the correct
  224. ***************
  225. *** 108,113 ****
  226. --- 112,120 ----
  227.   #ifndef    NTPINITFILE
  228.   #define    NTPINITFILE    "/etc/ntp.conf"
  229.   #endif
  230. + #ifndef    NTPDRIFTCOMP
  231. + #define    NTPDRIFTCOMP    "/etc/ntp.drift"
  232. + #endif
  233.   
  234.   struct list {
  235.       struct ntp_peer *head;
  236. ***************
  237. *** 286,291 ****
  238. --- 293,300 ----
  239.       int    flags;            /* local flags */
  240.   #define    PEER_FL_CONFIG        1
  241.   #define    PEER_FL_AUTHENABLE    2
  242. + #define    PEER_FL_SANE        0x0100    /* sane peer */
  243. + #define    PEER_FL_CANDIDATE    0x0200    /* candidate peer */
  244.   #define    PEER_FL_SYNC        0x1000    /* peer can bet sync'd to */
  245.   #define    PEER_FL_BCAST        0x2000    /* broadcast peer */
  246.   #define    PEER_FL_SELECTED    0x8000    /* actually used by query routine */
  247.  
  248. Index: ntp_proto.c
  249. *** ntp_proto.c.old    Wed May  3 15:18:48 1989
  250. --- ntp_proto.c    Wed May  3 15:18:56 1989
  251. ***************
  252. *** 1,5 ****
  253.   #ifndef    lint
  254. ! static char *rcsid = "$Source: /usr/users/louie/ntp/RCS/ntp_proto.c,v $ $Revision: 3.4.1.8 $ $Date: 89/04/10 15:57:59 $";
  255.   #endif
  256.   
  257.   /*
  258. --- 1,5 ----
  259.   #ifndef    lint
  260. ! static char *rcsid = "$Source: /usr/users/louie/ntp/RCS/ntp_proto.c,v $ $Revision: 3.4.1.9 $ $Date: 89/05/03 15:13:25 $";
  261.   #endif
  262.   
  263.   /*
  264. ***************
  265. *** 11,16 ****
  266. --- 11,20 ----
  267.   
  268.   /*
  269.    * $Log:    ntp_proto.c,v $
  270. +  * Revision 3.4.1.9  89/05/03  15:13:25  louie
  271. +  * Add code to count number of peer switches and inhibited peer switches.  Clock
  272. +  * selection code has been updated to reflect 21 April 1989 draft of NTP spec.
  273. +  * 
  274.    * Revision 3.4.1.8  89/04/10  15:57:59  louie
  275.    * New -l option for ntpd to enable logging for clock adjust messages.  Changed
  276.    * our idea of a bogus packet in the packet procedure to include a packet received
  277. ***************
  278. *** 118,123 ****
  279. --- 122,129 ----
  280.   
  281.   #include "ntp.h"
  282.   
  283. + int peer_switches, peer_sw_inhibited;
  284. + 
  285.   struct ntp_peer dummy_peer;
  286.   extern double WayTooBig;
  287.   extern unsigned long clock_watchdog;
  288. ***************
  289. *** 822,827 ****
  290. --- 828,834 ----
  291.       struct sel_lst {
  292.           struct ntp_peer *peer;
  293.           double distance;
  294. +         double precision;
  295.       } sel_lst[X_NTP_CANDIDATES];
  296.       int i, j, stratums, candidates;
  297.       int sanity_check();
  298. ***************
  299. *** 834,843 ****
  300. --- 841,852 ----
  301.           /*
  302.            * Check if this is a candidate for "sys.peer" 
  303.            */
  304. +         peer->flags &= ~(PEER_FL_SANE | PEER_FL_CANDIDATE);
  305.           if(sanity_check(peer)) {
  306.               sel_lst[candidates].peer = peer;
  307.               sel_lst[candidates].distance = peer->estdisp + 
  308.                   s_fixed_to_double(&peer->dispersion);
  309. +             peer->flags |= PEER_FL_SANE;
  310.               candidates++;
  311.           }
  312.           peer = peer->next;
  313. ***************
  314. *** 944,949 ****
  315. --- 953,959 ----
  316.       }
  317.       while (candidates > 1) {
  318.           double maxdispersion = 0.0, dispersion, weight;
  319. +         double min_precision_thres = 10e20, precision_thres;
  320.           short worst = 0;    /* shut up GNU CC about unused var */
  321.   #ifdef    DEBUG
  322.           if (debug > 3)
  323. ***************
  324. *** 954,959 ****
  325. --- 964,970 ----
  326.                  rest of the candidates */
  327.               dispersion = 0.0;
  328.               weight = 1.0;
  329. +             sel_lst[i].peer->flags |= PEER_FL_CANDIDATE;
  330.               for (j = 0; j < candidates; j++) {
  331.                   dtmp = sel_lst[j].peer->estoffset -
  332.                       sel_lst[i].peer->estoffset;
  333. ***************
  334. *** 965,983 ****
  335.               /* since we just happen to have this double floating
  336.                  around.. */
  337.               sel_lst[i].distance = dispersion;
  338.               if (dispersion >= maxdispersion) {
  339.                   maxdispersion = dispersion;
  340.                   worst = i;
  341.               }
  342.   #ifdef    DEBUG
  343.               if (debug > 4) {
  344. !                 printf(" peer %s => disp %f\n",
  345.                          ntoa(sel_lst[i].peer->src.sin_addr),
  346. !                        dispersion);
  347.               }
  348.   #endif
  349.           }
  350.   #ifdef    DEBUG
  351.           if (debug > 4)
  352.               printf(" peer %s => TOSS\n",
  353.                      ntoa(sel_lst[worst].peer->src.sin_addr));
  354. --- 976,1018 ----
  355.               /* since we just happen to have this double floating
  356.                  around.. */
  357.               sel_lst[i].distance = dispersion;
  358. +             
  359. +             precision_thres = NTP_MAXSKW + 1.0/(1<<-sys.precision);
  360. +             if (peer->precision < 0 &&
  361. +                 -peer->precision < sizeof(long)*NBBY)
  362. +                 precision_thres += 1.0/(1<<-peer->precision);
  363. + 
  364. +             sel_lst[i].precision = precision_thres;
  365. + 
  366.               if (dispersion >= maxdispersion) {
  367.                   maxdispersion = dispersion;
  368.                   worst = i;
  369.               }
  370. +             if (precision_thres < min_precision_thres) {
  371. +                 min_precision_thres = precision_thres;
  372. +             }
  373.   #ifdef    DEBUG
  374.               if (debug > 4) {
  375. !                 printf(" peer %s => disp %f prec_th %f\n",
  376.                          ntoa(sel_lst[i].peer->src.sin_addr),
  377. !                        dispersion, precision_thres);
  378.               }
  379.   #endif
  380.           }
  381. +         /*
  382. +          *  Now check to see if the max dispersion is greater than
  383. +          *  the min dispersion limit.  If so, crank again, otherwise
  384. +          *  bail out.
  385. +          */
  386. +         if (! (maxdispersion > min_precision_thres)) {
  387.   #ifdef    DEBUG
  388. +             if (debug > 4)
  389. +                 printf(" %d left valid\n", candidates);
  390. + #endif
  391. +             break;
  392. +         }
  393. +             
  394. + #ifdef    DEBUG
  395.           if (debug > 4)
  396.               printf(" peer %s => TOSS\n",
  397.                      ntoa(sel_lst[worst].peer->src.sin_addr));
  398. ***************
  399. *** 987,992 ****
  400. --- 1022,1028 ----
  401.            *  and interate until there is only one candidate peer left.
  402.            */
  403.           if (worst != candidates - 1) {
  404. +             sel_lst[worst].peer->flags &= ~PEER_FL_CANDIDATE;
  405.               for (i = worst, j = worst + 1; j < candidates; )
  406.                   sel_lst[i++].peer = sel_lst[j++].peer;
  407.           }
  408. ***************
  409. *** 997,1038 ****
  410.       if (debug > 3)
  411.           printf("select_clock: step6 %d candidates\n", candidates);
  412.   #endif
  413. -     if (sys.peer != NULL && sys.peer != sel_lst[0].peer) {
  414. -         /* 
  415. -          * Potential peer is different that current one; don't switch
  416. -          * to new peer unless the offset is suitably "large".
  417. -          */
  418. -         if (sys.peer->stratum == sel_lst[0].peer->stratum) {
  419. -             double threshold ;
  420.   
  421. !             threshold = NTP_MAXSKW +
  422. !                 1.0/(unsigned long)(1L << -sys.precision);
  423. ! 
  424. !             /* make sure we don't try to divide by zero */
  425. !             if (-sel_lst[0].peer->precision < sizeof(long)*NBBY)
  426. !                 threshold += 1.0/(unsigned long)
  427. !                     (1L << -sel_lst[0].peer->precision);
  428. ! 
  429. !             if (sel_lst[0].peer->estoffset < threshold) {
  430. ! #ifdef    DEBUG
  431. !                 if (debug > 2)
  432. !                     printf("clock: inhibit peer switch\n");
  433. ! #endif
  434.                   return;
  435.               }
  436. !         }         
  437.       }
  438.   
  439. ! #ifdef    DEBUG
  440. !     if ((debug > 2) || (sys.peer != sel_lst[0].peer))
  441. !         printf("clock: select peer %s stratum %d\n",
  442. !                ntoa(sel_lst[0].peer->src.sin_addr),
  443. !                sel_lst[0].peer->stratum);
  444. ! #endif
  445. ! 
  446. !     /* 
  447. !      *  We've finally selected our best bet for a clock to synchronize to.
  448.        */
  449.       if (sys.peer != sel_lst[0].peer) {
  450.           if (sys.peer != NULL)
  451.               syslog(LOG_INFO, "clock: select peer %s stratum %d was %s stratum %d",
  452. --- 1033,1072 ----
  453.       if (debug > 3)
  454.           printf("select_clock: step6 %d candidates\n", candidates);
  455.   #endif
  456.   
  457. !     /*
  458. !      *  Check to see if current peer is on the list of candidate peers.  If
  459. !      *  don't change sys.peer.  Note that if the first selected clock is
  460. !      *  at a higher stratum, don't even bother; we're going to want to
  461. !      *  switch to it.
  462. !      */
  463. !     if (sys.peer != NULL && 
  464. !         (sys.peer->stratum > sel_lst[0].peer->stratum)) {
  465. !         for (i = 0; i < candidates; i++) {
  466. !             if (sys.peer == sel_lst[i].peer) {
  467. !                 /*
  468. !                  * The clock we're currently synchronized to
  469. !                  * is among the candidate peers.  Don't switch.
  470. !                  */
  471. !                 if (i != 0) {
  472. !                     /*
  473. !                      *  Count instances where the best 
  474. !                      *  candidate is different from the
  475. !                      *  current clock, thus inhibiting
  476. !                      *  clockhopping.
  477. !                      */
  478. !                     peer_sw_inhibited++;
  479. !                 }
  480.                   return;
  481.               }
  482. !         }
  483.       }
  484.   
  485. !     /*
  486. !      *  The currently selected peer (if any) isn't on the candidate list.
  487. !      *  Grab the first one and let it be.
  488.        */
  489. + 
  490.       if (sys.peer != sel_lst[0].peer) {
  491.           if (sys.peer != NULL)
  492.               syslog(LOG_INFO, "clock: select peer %s stratum %d was %s stratum %d",
  493. ***************
  494. *** 1043,1053 ****
  495.               syslog(LOG_INFO, "clock: select peer %s stratum %d was UNSYNCED",
  496.                      ntoa(sel_lst[0].peer->src.sin_addr),
  497.                      sel_lst[0].peer->stratum);
  498.       }
  499. - 
  500. - 
  501. -     /* finally, set new peer */
  502. -     sys.peer = sel_lst[0].peer;
  503.   }
  504.   
  505.   int
  506. --- 1077,1092 ----
  507.               syslog(LOG_INFO, "clock: select peer %s stratum %d was UNSYNCED",
  508.                      ntoa(sel_lst[0].peer->src.sin_addr),
  509.                      sel_lst[0].peer->stratum);
  510. +         
  511. + #ifdef    DEBUG
  512. +         if (debug > 2)
  513. +             printf("clock: select peer %s stratum %d of %d cand\n",
  514. +                    ntoa(sel_lst[0].peer->src.sin_addr),
  515. +                    sel_lst[0].peer->stratum, candidates);
  516. + #endif
  517. +         sys.peer = sel_lst[0].peer;
  518. +         peer_switches++;
  519.       }
  520.   }
  521.   
  522.   int
  523.  
  524. Index: ntpd.c
  525. *** ntpd.c.old    Wed May  3 15:19:23 1989
  526. --- ntpd.c    Wed May  3 15:19:31 1989
  527. ***************
  528. *** 1,9 ****
  529.   #ifndef    lint
  530. ! static char *rcsid = "$Source: /usr/users/louie/ntp/RCS/ntpd.c,v $ $Revision: 3.4.1.7 $ $Date: 89/04/10 15:58:45 $";
  531.   #endif    lint
  532.   
  533.   /*
  534.    *  $Log:    ntpd.c,v $
  535.    * Revision 3.4.1.7  89/04/10  15:58:45  louie
  536.    * Add -l option to enable logging of clock adjust messages.
  537.    * 
  538. --- 1,14 ----
  539.   #ifndef    lint
  540. ! static char *rcsid = "$Source: /usr/users/louie/ntp/RCS/ntpd.c,v $ $Revision: 3.4.1.8 $ $Date: 89/05/03 15:16:17 $";
  541.   #endif    lint
  542.   
  543.   /*
  544.    *  $Log:    ntpd.c,v $
  545. +  * Revision 3.4.1.8  89/05/03  15:16:17  louie
  546. +  * Add code to save the value of the drift compensation register to a file every
  547. +  * hour.  Add additional configuration file directives which can specify the same
  548. +  * information as on the command line.
  549. +  * 
  550.    * Revision 3.4.1.7  89/04/10  15:58:45  louie
  551.    * Add -l option to enable logging of clock adjust messages.
  552.    * 
  553. ***************
  554. *** 115,120 ****
  555. --- 120,127 ----
  556.   char *prog_name;
  557.   
  558.   char *conf = NTPINITFILE;
  559. + char *driftcomp_file = NTPDRIFTCOMP;
  560. + static int drift_fd = -1;
  561.   
  562.   #ifdef    DEBUG
  563.   int debug = 0;
  564. ***************
  565. *** 275,286 ****
  566.           setlogmask(LOG_UPTO(LOG_INFO));
  567.   #endif    /* LOG_DAEMON */
  568.   
  569. !     syslog(LOG_NOTICE, "%s version $Revision: 3.4.1.7 $", prog_name);
  570.       syslog(LOG_NOTICE, "patchlevel %d", PATCHLEVEL);
  571.   
  572.   #ifdef    DEBUG
  573.       if (debug)
  574. !         printf("%s version $Revision: 3.4.1.7 $ patchlevel %d\n",
  575.                  prog_name, PATCHLEVEL);
  576.   #endif
  577.       (void) setpriority(PRIO_PROCESS, 0, -10);
  578. --- 282,293 ----
  579.           setlogmask(LOG_UPTO(LOG_INFO));
  580.   #endif    /* LOG_DAEMON */
  581.   
  582. !     syslog(LOG_NOTICE, "%s version $Revision: 3.4.1.8 $", prog_name);
  583.       syslog(LOG_NOTICE, "patchlevel %d", PATCHLEVEL);
  584.   
  585.   #ifdef    DEBUG
  586.       if (debug)
  587. !         printf("%s version $Revision: 3.4.1.8 $ patchlevel %d\n",
  588.                  prog_name, PATCHLEVEL);
  589.   #endif
  590.       (void) setpriority(PRIO_PROCESS, 0, -10);
  591. ***************
  592. *** 312,317 ****
  593. --- 319,331 ----
  594.       init_kern_vars();
  595.       init_logical_clock();
  596.   
  597. +     /*
  598. +      * Attempt to open for writing the file for storing the drift comp
  599. +      * register.  File must already exist for snapshots to be taken.
  600. +      */
  601. +     if ((i = open(driftcomp_file, O_WRONLY|O_CREAT, 0644)) >= 0) {
  602. +         drift_fd = i;
  603. +     }
  604.       (void) gettimeofday(&tv, (struct timezone *) 0);
  605.       srand(tv.tv_sec);
  606.   
  607. ***************
  608. *** 627,646 ****
  609.       register struct ntp_peer *peer = peer_list.head, *next;
  610.   #ifndef    XADJTIME2
  611.       extern void adj_host_clock();
  612. - #endif
  613.   
  614. ! #ifdef    REFCLOCK
  615. !     /*
  616. !      *  I think that this is being done wrong.  The reference clock 
  617. !      *  attached to this host should look like another peer.  Then the
  618. !      *  normal clock selection stuff will select the "right" one.
  619. !      */
  620. !     if (sys.stratum == 1)
  621. !         adj_from_source();
  622. !     else
  623. ! #endif    /* REFCLOCK */
  624. ! #ifndef    XADJTIME2
  625. !         adj_host_clock();
  626.   #endif
  627.       /*
  628.        * Count down sys.hold if necessary.
  629. --- 641,648 ----
  630.       register struct ntp_peer *peer = peer_list.head, *next;
  631.   #ifndef    XADJTIME2
  632.       extern void adj_host_clock();
  633.   
  634. !     adj_host_clock();
  635.   #endif
  636.       /*
  637.        * Count down sys.hold if necessary.
  638. ***************
  639. *** 720,725 ****
  640. --- 722,729 ----
  641.       int i;
  642.       int debuglevel;
  643.       int stagger = 0;
  644. +     double j;
  645. +     extern double drift_comp;
  646.   
  647.       bzero((char *) &sin, sizeof(sin));
  648.       fp = fopen(config, "r");
  649. ***************
  650. *** 747,753 ****
  651.                   } else
  652.                       trusting = atoi(name);
  653.               }
  654. !         } else if (strcmp(name, "debuglevel") == 0) {
  655.               if (fscanf(fp, "%d", &debuglevel) != 1)
  656.                   error = TRUE;
  657.   #ifdef    DEBUG
  658. --- 751,785 ----
  659.                   } else
  660.                       trusting = atoi(name);
  661.               }
  662. !         } else if (strcmp(name, "logclock") == 0) {
  663. !             if (fscanf(fp, "%s", name) != 1)
  664. !                 error = TRUE;
  665. !             else {
  666. !                 if (*name == 'Y' || *name == 'y') {
  667. !                     logstats = 1;
  668. !                 } else if (*name == 'N' || *name == 'n') {
  669. !                     logstats = 0;
  670. !                 } else
  671. !                     logstats = atoi(name);
  672. !             }
  673. !         } else if (strcmp(name, "driftfile") == 0) {
  674. !             if (fscanf(fp, "%s", name) != 1)
  675. !                 error = TRUE;
  676. !             else {
  677. !                 if (driftcomp_file = malloc(strlen(name)+1))
  678. !                     strcpy(driftcomp_file, name);
  679. !             }
  680. !         } else if (strcmp(name, "waytoobig") == 0 ||
  681. !                strcmp(name, "setthreshold") == 0) {
  682. !             if (fscanf(fp, "%s", name) != 1)
  683. !                 error = TRUE;
  684. !             else {
  685. !                 if (strcmp(name, "any") == 0)
  686. !                     WayTooBig = 10e15;
  687. !                 else
  688. !                     WayTooBig = atof(name);
  689. !             }
  690. !         } else if (strncmp(name, "debuglevel", 5) == 0) {
  691.               if (fscanf(fp, "%d", &debuglevel) != 1)
  692.                   error = TRUE;
  693.   #ifdef    DEBUG
  694. ***************
  695. *** 754,771 ****
  696.               else debug += debuglevel;
  697.   #endif
  698.           } else if (strcmp(name, "stratum") == 0) {
  699. !             if (fscanf(fp, "%d", &stratum) != 1)
  700. !                 error = TRUE;
  701. !             else sys.stratum = (u_char) stratum;
  702. !             if (sys.stratum == 1) {
  703. !                 if (fscanf(fp, "%4s", ref_clock) != 1)
  704. !                     error = TRUE;
  705. !                 else {
  706. !                     ref_clock[4] = 0;
  707. !                     (void) strncpy((char *) &sys.refid,
  708. !                                ref_clock, 4);
  709. !                 }
  710. !             }
  711.           } else if (strcmp(name, "precision") == 0) {
  712.               if (fscanf(fp, "%d", &precision) != 1)
  713.                   error = TRUE;
  714. --- 786,793 ----
  715.               else debug += debuglevel;
  716.   #endif
  717.           } else if (strcmp(name, "stratum") == 0) {
  718. !             fprintf(stderr, "Obsolete command 'stratum'\n");
  719. !             error = TRUE;
  720.           } else if (strcmp(name, "precision") == 0) {
  721.               if (fscanf(fp, "%d", &precision) != 1)
  722.                   error = TRUE;
  723. ***************
  724. *** 775,780 ****
  725. --- 797,813 ----
  726.               if (fscanf(fp, "%d", &i) != 1)
  727.                   error = TRUE;
  728.               else tickadj = i;
  729. +         } else if (strcmp(name, "settickadj") == 0) {
  730. +             if (fscanf(fp, "%s", name) != 1)
  731. +                 error = TRUE;
  732. +             else {
  733. +                 if (*name == 'Y' || *name == 'y') {
  734. +                     dotickadj = 1;
  735. +                 } else if (*name == 'N' || *name == 'n') {
  736. +                     dotickadj = 0;
  737. +                 } else
  738. +                     dotickadj = atoi(name);
  739. +             }
  740.   #endif
  741.   #ifdef    NOSWAP
  742.           } else if (strcmp(name, "noswap") == 0) {
  743. ***************
  744. *** 915,920 ****
  745. --- 948,969 ----
  746.   
  747.           exit(1);
  748.       }
  749. +     /*
  750. +      *  Read saved drift compensation register value.
  751. +      */
  752. +     if ((fp = fopen(driftcomp_file, "r")) != NULL) {
  753. +         if (fscanf(fp, "%f", &j) == 1 && j > -1.0 && j < 1.0) {
  754. +             drift_comp = j;
  755. +             syslog(LOG_INFO,
  756. +                    "Drift compensation value initialized to %f", j);
  757. +         } else {
  758. +             fprintf(stderr,
  759. +                 "init_ntp: bad drift compensation value\n");
  760. +             syslog(LOG_ERR,
  761. +                    "init_ntp: bad drift compensation value\n");
  762. +         }
  763. +         fclose(fp);
  764. +     }
  765.   }
  766.   
  767.   int kern_tickadj, kern_hz, kern_tick;
  768. ***************
  769. *** 1168,1183 ****
  770.   hourly() {
  771.       char buf[200];
  772.       register int p = 0;
  773.       extern double drift_comp, compliance;
  774.   
  775. !     (void) sprintf(buf, "stats: dc %f comp %f", drift_comp, compliance);
  776.   
  777.       if (sys.peer == NULL)
  778.           strcat(buf, " UNSYNC");
  779.       else {
  780.           p = strlen(buf);
  781. !         (void) sprintf(buf + p, " SYNC %s %d",
  782. !             ntoa(sys.peer->src.sin_addr), sys.peer->stratum);
  783.       }
  784.       syslog(LOG_INFO, buf);
  785.   #ifdef    DEBUG
  786. --- 1217,1239 ----
  787.   hourly() {
  788.       char buf[200];
  789.       register int p = 0;
  790. +     static double drifts[5] = { 0.0, 0.0, 0.0, 0.0, 0.0 };
  791. +     static int drift_count = 0;
  792.       extern double drift_comp, compliance;
  793. +     extern int peer_switches, peer_sw_inhibited;
  794.   
  795. !     (void) sprintf(buf, "stats: dc %f comp %f peersw %d inh %d",
  796. !                drift_comp, compliance, peer_switches,
  797. !                peer_sw_inhibited);
  798.   
  799.       if (sys.peer == NULL)
  800.           strcat(buf, " UNSYNC");
  801.       else {
  802.           p = strlen(buf);
  803. !         (void) sprintf(buf + p, " off %f SYNC %s %d",
  804. !                    sys.peer->estoffset,
  805. !                    ntoa(sys.peer->src.sin_addr),
  806. !                    sys.peer->stratum);
  807.       }
  808.       syslog(LOG_INFO, buf);
  809.   #ifdef    DEBUG
  810. ***************
  811. *** 1184,1189 ****
  812. --- 1240,1269 ----
  813.       if (debug)
  814.           puts(buf);
  815.   #endif
  816. +     /*
  817. +      *  If the drift compensation snapshot file is open, then write
  818. +      *  the current value to it.  Since there's only one block in the
  819. +      *  file, and no one else is reading it, we'll just keep the file
  820. +      *  open and write to it.
  821. +      */
  822. +     if (drift_fd >= 0) {
  823. +         drifts[drift_count % 5] = drift_comp;
  824. +         /* works out to be 70 bytes */
  825. +         (void) sprintf(buf,
  826. +              "%+12.10f %+12.10f %+12.10f %+12.10f %+12.10f %4d\n",
  827. +                    drifts[drift_count % 5],
  828. +                    drifts[(drift_count+4) % 5],
  829. +                    drifts[(drift_count+3) % 5],
  830. +                    drifts[(drift_count+2) % 5],
  831. +                    drifts[(drift_count+1) % 5],
  832. +                    drift_count + 1);
  833. + 
  834. +         (void) lseek(drift_fd, 0L, L_SET);
  835. +         if (write(drift_fd, buf, strlen(buf)) < 0) {
  836. +             syslog(LOG_ERR, "Error writing drift comp file: %m");
  837. +         }
  838. +         drift_count++;
  839. +     }
  840.   }
  841.   
  842.   #if    defined(DEBUG) && defined(SIGUSR1) && defined(SIGUSR2)
  843.  
  844. Index: ntpdc.c
  845. *** ntpdc.c.old    Wed May  3 15:19:48 1989
  846. --- ntpdc.c    Wed May  3 15:19:51 1989
  847. ***************
  848. *** 1,9 ****
  849.   #ifndef    lint
  850. ! static char *RCSid = "$Source: /usr/users/louie/ntp/RCS/ntpdc.c,v $ $Revision: 3.4.1.5 $ $Date: 89/04/08 10:38:06 $";
  851.   #endif
  852.   
  853.   /*
  854.    * $Log:    ntpdc.c,v $
  855.    * Revision 3.4.1.5  89/04/08  10:38:06  louie
  856.    * Minor cosmetic changes and removed dead debug code from ntpd.c
  857.    * 
  858. --- 1,13 ----
  859.   #ifndef    lint
  860. ! static char *RCSid = "$Source: /usr/users/louie/ntp/RCS/ntpdc.c,v $ $Revision: 3.4.1.6 $ $Date: 89/05/03 15:17:27 $";
  861.   #endif
  862.   
  863.   /*
  864.    * $Log:    ntpdc.c,v $
  865. +  * Revision 3.4.1.6  89/05/03  15:17:27  louie
  866. +  * ntpdc now will display addional peer flags which indicate how far through
  867. +  * the clock selection process a peer was considered.
  868. +  * 
  869.    * Revision 3.4.1.5  89/04/08  10:38:06  louie
  870.    * Minor cosmetic changes and removed dead debug code from ntpd.c
  871.    * 
  872. ***************
  873. *** 287,292 ****
  874. --- 291,297 ----
  875.       double offset[PEER_SHIFT], delay[PEER_SHIFT], dsp,del,off;
  876.       char c;
  877.       char *cvthname();
  878. +     int flags;
  879.   
  880.       sin.sin_addr.s_addr = n->net_address;
  881.       for (i = 0; i < PEER_SHIFT; i++) {
  882. ***************
  883. *** 297,305 ****
  884.       del = (long) ntohl(n->estdelay);    /* leave in milliseconds */
  885.       off = (long) ntohl(n->estoffset);    /* leave in milliseconds */
  886.       c = ' ';
  887. !     if (ntohs(n->flags) & PEER_FL_CONFIG)
  888.           c = '-';        /* mark pre-configured */
  889. !     if (ntohs(n->flags) & PEER_FL_SELECTED)
  890.           c = '*';        /* mark peer selection */
  891.       sin.sin_addr.s_addr = n->net_address;
  892.       printf("%c%-15.15s ", c, cvthname(&sin));
  893. --- 302,315 ----
  894.       del = (long) ntohl(n->estdelay);    /* leave in milliseconds */
  895.       off = (long) ntohl(n->estoffset);    /* leave in milliseconds */
  896.       c = ' ';
  897. !     flags = ntohs(n->flags);
  898. !     if (flags & PEER_FL_CONFIG)
  899.           c = '-';        /* mark pre-configured */
  900. !     if (flags & PEER_FL_SANE)
  901. !         c = '.';        /* passed sanity check */
  902. !     if (flags & PEER_FL_CANDIDATE)
  903. !         c = '+';        /* made candidate list */
  904. !     if (flags & PEER_FL_SELECTED)
  905.           c = '*';        /* mark peer selection */
  906.       sin.sin_addr.s_addr = n->net_address;
  907.       printf("%c%-15.15s ", c, cvthname(&sin));
  908.